import KafkaSink.Base
import org.apache.flink.api.common.functions.MapFunction
import org.apache.flink.api.common.typeinfo.Types
import org.apache.flink.streaming.api.datastream.DataStreamSource
import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment

/**
 *
 * @author Spring_Hu
 * @date 2021/10/10 21:06
 */
object Map extends Base {
  def main(args: Array[String]): Unit = {
    run{
      ds.map(new MapFunction[Int,Int] {
        override def map(value: Int) = {
          value
        }
      }).returns(classOf[Int]).print()
    }
  }
}
